google.golang.org/grpc.csAttempt.s (field)
35 uses
google.golang.org/grpc (current package)
rpc_util.go#L210: *o.HeaderAddr, _ = attempt.s.Header()
rpc_util.go#L232: *o.TrailerAddr = attempt.s.Trailer()
rpc_util.go#L254: if x, ok := peer.FromContext(attempt.s.Context()); ok {
stream.go#L492: a.s = s
stream.go#L554: s *transport.Stream
stream.go#L602: if a.s == nil && a.allowTransparentRetry {
stream.go#L607: if a.s != nil {
stream.go#L608: <-a.s.Done()
stream.go#L609: unprocessed = a.s.Unprocessed()
stream.go#L621: if a.s != nil {
stream.go#L622: if !a.s.TrailersOnly() {
stream.go#L628: sps := a.s.Trailer()["grpc-retry-pushback-ms"]
stream.go#L645: if a.s != nil {
stream.go#L646: code = a.s.Status().Code()
stream.go#L720: if cs.attempt.s != nil {
stream.go#L721: return cs.attempt.s.Context()
stream.go#L758: <-a.s.Done()
stream.go#L760: if err == nil || (err == io.EOF && a.s.Status().Code() == codes.OK) {
stream.go#L777: m, err = a.s.Header()
stream.go#L818: if cs.attempt.s == nil {
stream.go#L821: return cs.attempt.s.Trailer()
stream.go#L943: a.t.Write(a.s, nil, nil, &transport.Options{Last: true})
stream.go#L978: if cs.attempt.s != nil {
stream.go#L1020: if err := a.t.Write(a.s, hdr, payld, &transport.Options{Last: !cs.desc.ClientStreams}); err != nil {
stream.go#L1046: if ct := a.s.RecvCompress(); ct != "" && ct != encoding.Identity {
stream.go#L1060: err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decomp)
stream.go#L1063: if statusErr := a.s.Status().Err(); statusErr != nil {
stream.go#L1098: err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decomp)
stream.go#L1103: return a.s.Status().Err() // non-server streaming Recv returns nil on success
stream.go#L1120: if a.s != nil {
stream.go#L1121: a.t.CloseStream(a.s, err)
stream.go#L1122: tr = a.s.Trailer()
stream.go#L1127: if a.s != nil {
stream.go#L1128: br = a.s.BytesReceived()
stream.go#L1133: BytesSent: a.s != nil,